package com.gang.listener;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.springframework.stereotype.Component;

/**
 * @author maj
 * @ClassName ConsumerMessageListener
 * @Description
 * @date 2020-06-25 18:58
 */
public class ConsumerMessageListener implements MessageListener {

  @Override
  public void onMessage(Message message) {
    //这里我们知道生产者发送的就是一个纯文本消息，
    // 所以这里可以直接进行强制转换，或者直接把onMessage方法的参数改成Message的子类TextMessage
    TextMessage textMsg = (TextMessage) message;

    try {
      message.acknowledge();
      System.out.println("消息内容是：" + textMsg.getText());
    } catch (JMSException e) {
      e.printStackTrace();
    }
  }
}
